package com.eastfair.datasync.listener;

import com.alibaba.fastjson.JSONObject;
import com.eastfair.datasync.entity.CanalData;

public interface SyncInterfaceOfJson {
    /**
     * 添加操作
     *
     * @param canalData
     */
    void executeInsert(CanalData canalData);

    /**
     * 更新操作
     *
     * @param canalData
     */
    void executeUpdate(CanalData canalData);

    /**
     * 添加字段操作
     *
     * @param canalData
     */
    void executeAlter(CanalData canalData);


    /**
     * 整体执行
     *
     * @param message
     * @param t
     */
    void executeAll(String message, JSONObject t);
}
